//package com.example.b;
//
//import ch.qos.logback.core.joran.util.beans.BeanDescriptionFactory;
//import io.vertx.core.AbstractVerticle;
//import io.vertx.core.Vertx;
//import io.vertx.ext.web.Router;
//import io.vertx.ext.web.handler.WebSocketHandler;
//
//
//public class BSystemServer extends AbstractVerticle {
//
//    @Override
//    public void start() {
//        // 创建路由
//        Router router = Router.router(vertx);
//
//        // 配置 WebSocket 处理器
//        BeanDescriptionFactory WebSocketHandler;
//        router.route("/ws").handler(WebSocketHandler.create(vertx)
//                .onWebSocket(webSocket -> {
//                    System.out.println("B系统：A系统已连接");
//
//                    // 接收 A 系统发送的消息
//                    webSocket.textMessageHandler(message -> {
//                        System.out.println("B系统收到消息：" + message);
//                        // 可选：回复消息给 A 系统
//                        webSocket.writeTextMessage("B系统已收到：" + message);
//                    });
//
//                    // 处理连接关闭
//                    webSocket.closeHandler(v -> {
//                        System.out.println("B系统：A系统断开连接");
//                    });
//
//                    // 处理异常
//                    webSocket.exceptionHandler(e -> {
//                        System.err.println("B系统WebSocket异常：" + e.getMessage());
//                    });
//                })
//        );
//
//        // 启动 HTTP 服务器（WebSocket 基于 HTTP 握手）
//        vertx.createHttpServer()
//                .requestHandler(router)
//                .listen(8080, res -> {
//                    if (res.succeeded()) {
//                        System.out.println("B系统WebSocket服务启动成功，端口：8080");
//                    } else {
//                        System.err.println("B系统启动失败：" + res.cause().getMessage());
//                    }
//                });
//    }
//
//    public static void main(String[] args) {
//        // 启动 Vert.x 并部署服务端 Verticle
//        Vertx.vertx().deployVerticle(new BSystemServer());
//    }
//}